package com.shujia.sink

import org.apache.hadoop.hbase.client.Put

// 构建put
trait HbaseMapper[IN] extends Serializable {
  def mapper(value: IN): Put
}
